<?php

// 接收地理位置信息
return function($postObj){
	$latitude = $postObj->Location_X;
	$longitude = $postObj->Location_Y;
	$scale = $postObj->Scale;							// 地图缩放大小
	$label = $postObj->Label;							// 地理位置信息
	$fromUsername = $postObj->FromUserName;		// 发送方帐号（一个OpenID）
	// 只能显示中国的天气
	if(mb_substr($label, 0, 2) == "中国") $label = mb_substr($label, 2);
	// 清理掉地址中不需要的部分
	if(mb_strpos($label, "邮政编码")) $label = trim(mb_substr($label, 0, mb_strpos($label, "邮政编码")));
	// 提取省市信息
	preg_match("/(.*?)省(.*?)市/",$label,$adds);
	$province = $adds[1];
	$city = $adds[2];
	
	$db = init_db();
	$db->startTrans();
	
	try{
	
		$row = $db->get_row("select * from chat_user where source='wechat' and user='{$fromUsername}'");
		if(false === $row){
			$db->query("insert into chat_user(source,user,latitude,longitude,scale,label,last_visited,province,city) values('wechat', '{$fromUsername}',{$latitude}, {$longitude},{$scale},'{$label}', '" . date("Y-m-d H:i:s") . "','{$province}','{$city}')");
		}else{
			$db->query("update chat_user set last_visited='" . date("Y-m-d H:i:s") . "',latitude={$latitude},longitude={$longitude},province='{$province}',city='{$city}',label='{$label}',scale={$scale} where id=$row[id]");
		}
		
		reply_text_msg($postObj, "你当前的位置是：{$label}。");
		
		$db->commit();
	
	}catch(Exception $e){
		$db->rollback();
	}
		

	
};